package io.persimmon.queue.core;

import io.persimmon.queue.bo.Context;
import io.persimmon.queue.bo.Listener;
import io.persimmon.queue.bo.Message;

public interface Queue<T, C extends Context, M extends Message<T>> {
    void registerListener(Listener<T, M> listener, C context);

    void publishMessage(M message, C context);
}
